package com.yt.lxh.constant;

public class MQConst {
    /**
     * 消息补偿
     */
    public static final String MQ_KEY_PREFIX = "lxh.mq:list";
    public static final int RETRY_COUNT = 3;

    /**
     * 商品上下架
     */
    // 产品销售状态更新交换机
    public static final String GOODS_DIRECT_EXCHANGE = "lxh.goods.direct";
    // 产品销售状态上架队列
    public static final String GOODS_UPPER_QUEUE = "lxh.goods_upper_queue";
    // 产品销售状态下架队列
    public static final String GOODS_LOWER_QUEUE = "lxh.goods_lower_queue";
    // 产品销售状态上架 Key
    public static final String GOODS_UPPER_KEY = "lxh.goods_upper_key";
    // 产品销售状态下架 Key
    public static final String GOODS_LOWER_KEY = "lxh.goods_lower_key";

    /**
     * 营销活动
     */
    // 延迟交换机 发布优惠券
    public static final String COUPON_PUBLISH_DELAYED_EXCHANGE = "lxh.coupon_publish_delayed_exchange";
    // 延迟队列 发布优惠券
    public static final String COUPON_PUBLISH_DELAYED_QUEUE = "lxh.coupon_publish_delayed_queue";
    // 发布 / 过期 优惠券 routingKey
    public static final String COUPON_PUBLISH_KEY = "lxh.coupon_publish_key";

    /**
     * 团长上下线
     */
    public static final String EXCHANGE_LEADER_DIRECT = "lxh.leader.direct";
    public static final String ROUTING_LEADER_UPPER = "lxh.leader.upper";
    public static final String ROUTING_LEADER_LOWER = "lxh.leader.lower";
    //队列
    public static final String QUEUE_LEADER_UPPER  = "lxh.leader.upper";
    public static final String QUEUE_LEADER_LOWER  = "lxh.leader.lower";

    //订单
    public static final String EXCHANGE_ORDER_DIRECT = "lxh.order.direct";
    public static final String ROUTING_ROLLBACK_STOCK = "lxh.rollback.stock";
    public static final String ROUTING_MINUS_STOCK = "lxh.minus.stock";

    public static final String ROUTING_DELETE_CART = "lxh.delete.cart";
    //解锁普通商品库存
    public static final String QUEUE_ROLLBACK_STOCK = "lxh.rollback.stock";
    public static final String QUEUE_SECKILL_ROLLBACK_STOCK = "lxh.seckill.rollback.stock";
    public static final String QUEUE_MINUS_STOCK = "lxh.minus.stock";
    public static final String QUEUE_DELETE_CART = "lxh.delete.cart";

    //支付
    public static final String EXCHANGE_PAY_DIRECT = "lxh.pay.direct";
    public static final String ROUTING_PAY_SUCCESS = "lxh.pay.success";
    public static final String QUEUE_ORDER_PAY  = "lxh.order.pay";
    public static final String QUEUE_LEADER_BILL  = "lxh.leader.bill";

    //取消订单
    public static final String EXCHANGE_CANCEL_ORDER_DIRECT = "lxh.cancel.order.direct";
    public static final String ROUTING_CANCEL_ORDER = "lxh.cancel.order";
    //延迟取消订单队列
    public static final String QUEUE_CANCEL_ORDER  = "lxh.cancel.order";

    /**
     * 定时任务
     */
    public static final String EXCHANGE_DIRECT_TASK = "lxh.exchange.direct.task";
    public static final String ROUTING_TASK_23 = "lxh.task.23";
    //队列
    public static final String QUEUE_TASK_23  = "lxh.queue.task.23";
}
